package com.lhq.message.kafka.listener;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class MyKafkaListener {

    @KafkaListener(id = "webGroup", topics = "test")
    public void listen(String input) {
        System.out.println("input value: {}"+ input);

    }
}
